package com.lh.threadtest.test3;

import java.util.HashSet;
import java.util.Iterator;
import java.util.Set;

/***
 * 
* @ClassName: Test 
* @Description: 面试题3
* @author Liu
* @date 2018年1月19日 下午3:46:27 
*
 */
//不能改动此Test类	
public class TestImpl extends Thread {

	private TestDo2 testDo;
	private String key;
	private String value;

	public TestImpl(String key, String key2, String value) {
		this.testDo = TestDo2.getInstance();
		/*
		 * 常量"1"和"1"是同一个对象，下面这行代码就是要用"1"+""的方式产生新的对象，
		 * 以实现内容没有改变，仍然相等（都还为"1"），但对象却不再是同一个的效果
		 * 
		 * 注意：
		 *  String a = "1" + "";
		 *  String b = "1" + "";
		 *  这种字符串字面量是同一个对象！！！(编译器会优化)
		 *  
		 *  this.key = key + key2;
		 *  变量这种不是同一个对象！！！
		 * 
		 */
		this.key = key + key2;
		this.value = value;
	}

	public static void main(String[] args) throws InterruptedException {
		TestImpl a = new TestImpl("1", "", "1");
		TestImpl b = new TestImpl("1", "", "2");
		TestImpl c = new TestImpl("3", "", "3");
		TestImpl d = new TestImpl("4", "", "4");
		System.out.println("begin:" + (System.currentTimeMillis() / 1000));
		a.start();
		b.start();
		c.start();
		d.start();

	}

	public void run() {
		testDo.doSome(key, value);
	}
}

class TestDo2 {

	private TestDo2() {
	}

	private static TestDo2 _instance = new TestDo2();

	public static TestDo2 getInstance() {
		return _instance;
	}
	
	private Set<Object> set = new HashSet<>();

	public void doSome(Object key, String value) {
		if(!set.contains(key)){
			set.add(key);
		}else {
			for(Iterator<Object> iterator = set.iterator();iterator.hasNext();){
//				try {
//					TimeUnit.MILLISECONDS.sleep(200);
//				} catch (InterruptedException e) {
//					e.printStackTrace();
//				}
				Object obj = iterator.next();
				if(obj.equals(key)){
					key = obj;
				}
			}
		}
		
		synchronized (key)
			// 以大括号内的是需要局部同步的代码，不能改动!
			{
				try {
					Thread.sleep(1000);
					System.out.println(key + ":" + value + ":" + (System.currentTimeMillis() / 1000));
				} catch (InterruptedException e) {
					e.printStackTrace();
				}
			}
	}

}